let mysql = require('mysql');

//创建连接池
var pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: 'china520',
    port: 3306,
    database: 'movienetwork',
    // 是否允许多条sql语句同时执行（默认false）
    multipleStatements: true
});

// 把pool.query() 封装
//  module.exports


module.exports = {
    query: (sql) => {
        return new Promise((resolve, reject) => {
            pool.query(sql, (err, result) => {
                if (err) {
                    reject({
                        state: false,
                        msg: '失败'
                    })
                }
                else {
                    resolve({
                        state: true,
                        msg: '成功',
                        data: result
                    })
                }
            })
        })
    }
}
